package com.doit.demo.day04;

/**
 * @DATE 2022/2/17/9:21
 * @Author MDK
 * @Version 2021.2.2
 *
 * max与maxBy:底层都是reduce
 *      如果底层只有两个比较字段,两个方法没有区别
 *      如果底层有多个比较字段,maxBy会返回参与比较字段,预期的最大值及它们所在数据的其他所有字段
 *      max:
 *      maxBy:
 *
 * rescale可以尽量减少网络传输
 * rebalance在不同TaskManager之间传输
 *
 * 将数据进行广播,将一个数据放到下游所有的channel中
 **/
public class MaxDemo1 {
    public static void main(String[] args) {

    }
}
